+# Copyright (C) 2005 Christian Limpach <Christian.Limpach@cl.cam.ac.uk>
+
+# This file is subject to the terms and conditions of the GNU General
+# Public License. See the file "COPYING" in the main directory of
+# this archive for more details.
import select
import threading
threadcond = threading.Condition()
xs = None
xslock = threading.Lock()
- watches = []
def __init__(self, path, fn, args=(), kwargs={}):
self.fn = fn
xswatch.xslock.acquire()
xswatch.xs.watch(path, self)
xswatch.xslock.release()
- xswatch.watches.append(self)
def watchStart(cls):
cls.threadcond.acquire()